package conAbstract

import (
	"base/common/log"
	"encoding/json"
)

var Sleeptime int64 = 1

// 消费者接口
type Consumer interface {
	Handle(data map[string]any) error //消费方法
	Error(err error)                  //错误处理
}

// 将json 转为 map[string]any
func GetMapData(jsonStr string) (map[string]any, error) {

	data := map[string]any{}

	// 使用json.Unmarshal将JSON字符串解码为map
	err := json.Unmarshal([]byte(jsonStr), &data)

	if err != nil {
		log.ELog("读取队列json转map失败", map[string]any{
			"Data": jsonStr,
			"err":  err.Error(),
		})
	}

	return data, err
}
